package com.hmall.trade.domain.implObj;

import com.hmall.trade.constants.MQConstants;
import org.springframework.amqp.AmqpException;
import org.springframework.amqp.core.Message;
import org.springframework.amqp.core.MessagePostProcessor;

public class CommonMessagePostProcessor implements MessagePostProcessor {
    @Override
    public Message postProcessMessage(Message message) throws AmqpException {
        message.getMessageProperties().setDelay(MQConstants.ORDER_QUEUE_TTL);
        return message;
    }
}
